package org.zn.etl.job.dao;

import java.util.List;

import org.apache.ibatis.annotations.Param;
import org.zn.etl.job.entity.po.DataMappingPo;

public interface DataMappingMapper {
    int deleteByPrimaryKey(Long id);

    int insert(DataMappingPo row);

    DataMappingPo selectByPrimaryKey(Long id);

    List<DataMappingPo> selectAll();

    int updateByPrimaryKey(DataMappingPo row);
    
    /**
     * 查询job 映射
     * @param jobId
     * @return
     */
    List<DataMappingPo> selectByJobid(@Param("jobid") Long jobId);
    
    
    /**
     * 查询job 映射
     * @param jobId
     * @return
     */
    List<DataMappingPo> tableRef(@Param("schema") String schema,@Param("tables") String tables);
}